# celery 启动文件
from celery import Celery

# 为 celery 使用 Django 配置文件进行设置
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings')

# 1. 创建 celery 实例
celery_app = Celery('celery_tasks')

# 2. 加载 celery 配置
# 我们通过加载配置文件来设置 broker
celery_app.config_from_object('celery_tasks.config')

# 3. 自动注册 celery 任务
# 需要 celery 自动检测指定包的任务
# autodiscover_tasks 参数是列表
# 列表中的元素是 tasks 的路径
celery_app.autodiscover_tasks(['celery_tasks.sms'])
